//package org.ricks.robot;
//
//import org.ricks.common.utils.RandomUtils;
//import org.ricks.ioc.TaskBus;
//import org.ricks.net.transport.kcp.KcpSession;
//import org.ricks.robot.business.RobotAction;
//
//import java.util.HashMap;
//import java.util.Map;
//import java.util.concurrent.TimeUnit;
//
//public class RobotManager {
//
//    public final static Map<KcpSession, RobotInfo> robotMap = new HashMap<>();
//
//
//    public static void login(KcpSession session, String robotAccount ) {
//
//        RobotInfo robotInfo = new RobotInfo(session ,robotAccount);
//
//        robotMap.put(session, robotInfo);
//    }
//
//    public static RobotInfo get(KcpSession session) {
//        return robotMap.get(session);
//    }
//
//    public static void startRun() {
//        long time = 1000;
//        for (KcpSession session: robotMap.keySet()) {
//            time = time + RandomUtils.randomInt(1000, 5000);
//            long finalTime = time;
//            RobotRun.scheduledExecutorService.schedule(() -> TaskBus.execute(session, () -> RobotAction.robotStart(session)) , finalTime, TimeUnit.MILLISECONDS);
//
////            TaskBus.execute(session, () -> RobotAction.robotStart(session));
//
//        }
//    }
//
//}
